package com.freeedu.mq01;

import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.common.message.Message;

/**
 * Hello world!
 *
 */
public class App 
{
    public static void main( String[] args ) throws Exception
    {
    	DefaultMQProducer producer =   new DefaultMQProducer("xxoogroup");
    	// 设置nameserver 的地址
    	producer.setNamesrvAddr("192.168.2.123:9876");

    	// 启动
    	producer.start();
    	
    	// 发送消息  主题（队列会自动分配） ， 数据 
    	Message msg = new Message("topic01","测试".getBytes());
    	// 同步
    	producer.send(msg);
    	
    	// 关闭
    	producer.shutdown();
    }
}
